package com.example.messagequeue.common.OPOther;import com.example.messagequeue.common.BasicReturns;import com.example.messagequeue.mqserver.core.BasicPropertise;import lombok.Data;import java.io.Serializable;/** * 把订阅的消息返回给客户端，相当于一个Message */@Datapublic class SubScribeReturns extends BasicReturns implements Serializable {    /**     * 消费者唯一标识，和channelId相同     */     private String consumerTag;     //消息头     private BasicPropertise basicPropertise;     //消息体    private byte[] body;}